import celery

#消息中间件(redis)
broker='redis://127.0.0.1:6379/2'  #1代表使用第一个库

#结果存储(redis)
backend='redis://127.0.0.1:6379/4' #2代表使用第一个库
#实例化得到对象，指定中间件和结果存储
app=celery.Celery('test',broker=broker,backend=backend)


@app.task
def add(a,b):
    # count=1
    # for i in range(10000):
    #     count+=i
    #     count*=i
    #     count += i
    #     count *= i
    return a+b

@app.task
def mul(a,b):
    return a*b

